package com.settlement.system.handler.disruptor;

import com.lmax.disruptor.EventHandler;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

public class OrderConsumer implements EventHandler<MessageVo> {


    private static final Logger logger = LoggerFactory.getLogger(OrderConsumer.class);


    public OrderConsumer() {
    }


    @Override
    public void onEvent(MessageVo messageVo, long l, boolean b) {
        logger.info("接收到消息："+ messageVo.toString());
    }
}
